package com.learn.kafka.stream.config;

import java.util.Properties;

/**
 * 接口 KafkaConfigurable（定义配置操作标准）
 *
 * @author: MI
 * @email: 448341911@qq.com
 * @createTime: 2025/8/7 21:15
 * @updateUser: MI
 * @updateTime: 2025/8/7 21:15
 * @updateRemark: 修改内容
 * @version: 1.0
 */
public interface KafkaConfiguration {

    /**
     * 获取完整配置对象
     *
     * @return 配置Properties
     */
    Properties getProps();

    /**
     * 动态修改配置项
     *
     * @param key   配置键（如 ProducerConfig.BOOTSTRAP_SERVERS_CONFIG）
     * @param value 配置值
     */
    void setConfig(String key, String value);
}
